d2f148940680b0112fd70681352ad01b8da58b1b,src/test/java/reactor/core/publisher/FluxPublishOnTest.java,FluxPublishOnTest,crossRangeHidden,#,618
Before Change
@Test
public void crossRangeHidden() {
AssertSubscriber<Integer> ts = AssertSubscriber.create();
int count = 1000000;
Flux.range(1, count)
.hide()
.flatMap(v -> Flux.range(v, 2)
.hide(), false, 128, 1)
.hide()
.publishOn(Schedulers.fromExecutorService(exec))
.subscribe(ts);
if (!ts.await(Duration.ofSeconds(5))
.isTerminated()) {
ts.cancel();
}
ts.assertValueCount(count * 2)
After Change
public void crossRangeHidden() {
int count = 1000000;
StepVerifier.create(Flux.range(1, count)
.hide()
.flatMap(v -> Flux.range(v, 2)
.hide(), false, 128, 1)
.hide()
.publishOn(Schedulers.fromExecutorService(exec)))
.expectNextCount(2 * count)
.verifyComplete();
}
@Test